package com.smarthome.ipc;

// public class IpcClientHandler extends IoHandlerAdapter {
//
// private static final Logger LOGGER = LoggerFactory.getLogger(IpcClientHandler.class);
//
// @Override
// public void messageReceived(IoSession session, Object message) throws Exception {
// String requestStr = message.toString();
// if (!StringUtils.isBlank(requestStr)) {
// requestStr = requestStr.replaceAll("\\\\\"", "\"");
// requestStr = requestStr.substring(1, requestStr.length() - 1);
// LOGGER.info("客户端收到消息：" + requestStr);
// JSONObject requestObj = JSONObject.parseObject(requestStr);
// String commandName = requestObj.getString(IpcConstants.IPC_COMMAND_NAME);
// if (!StringUtils.isBlank(commandName)) {
// IpcResponse<?> response = CommandExporter.doCommand(null, requestObj);
// String responseStr = CommandExporter.parseJsonForIpcResponse(response);
// session.write(responseStr);
// }
// }
// }
//
// @Override
// // 客户端异常
// public void exceptionCaught(IoSession session, Throwable cause) throws Exception {
// super.exceptionCaught(session, cause);
// cause.printStackTrace();
// }
//
// @Override
// // 客户端消息发送
// public void messageSent(IoSession iosession, Object message) throws Exception {
// super.messageSent(iosession, message);
// LOGGER.info("客户端消息发送：" + message.toString());
// }
//
// @Override
// // 客户端会话关闭
// public void sessionClosed(IoSession iosession) throws Exception {
// super.sessionClosed(iosession);
// }
//
// @Override
// // 客户端会话创建
// public void sessionCreated(IoSession iosession) throws Exception {
// super.sessionCreated(iosession);
// }
//
// @Override
// // 客户端会话休眠
// public void sessionIdle(IoSession iosession, IdleStatus idlestatus) throws Exception {
// super.sessionIdle(iosession, idlestatus);
// }
//
// @Override
// // 客户端会话打开
// public void sessionOpened(IoSession iosession) throws Exception {
// super.sessionOpened(iosession);
// }
//
// }